package com.neo.push.core.connection;

import com.neo.push.core.TextMessage;

/**
 * Created by lock on 17-7-11.
 */
public interface MessageWriter<T extends TextMessage> {

    /**
     * 发送消息
     * @param connection    当前连接
     * @param textMessage   文本消息
     * @throws Exception
     */
    void writeMessage(SocketConnection connection,T textMessage) throws Exception;

}
